package com.passion.mq.core;

import java.util.Map;

/**
 * 类描述：发送MQ消息顶级接口
 *
 * @author ZhuYin
 * @since 2024年12月16日
 */
public interface MqSender {

    /**
     * 发送消息到指定的主题/队列
     *
     * @param topicOrQueue 消息的目标主题或队列名称
     * @param message      要发送的消息内容
     */
    void sendMessage(String topicOrQueue, String message);

    /**
     * 发送带有额外属性的消息
     *
     * @param topicOrQueue 消息的目标主题或队列名称
     * @param message      要发送的消息内容
     * @param properties   消息的附加属性（如头部信息）
     */
    void sendMessage(String topicOrQueue, String message, Map<String, Object> properties);

}
